package cn.getech.data.development.service;

import cn.getech.data.development.model.vo.RealTimeTaskVO;

import java.util.Map;

public interface FLinkService {

    /**
     * 运行任务
     * @return
     */
    Map<String, String> run(RealTimeTaskVO task);

    void cancel(RealTimeTaskVO task);

    String getAppId(String logfile);

    String pause(RealTimeTaskVO task);

    void saveConfig(RealTimeTaskVO taskVO);

    void saveLocalConfig(RealTimeTaskVO task);

    Map<String, String> localRun(RealTimeTaskVO task);


    String getDebugData(String appId);
}
